package com.example.demo.member.controller;

import java.util.LinkedList;
import java.util.Queue;

public class RequestCollector {

    public static void main(String[] args) {

        //        ConcurrentLinkedQueue<String> queue = new ConcurrentLinkedQueue<>();
        //
        //        for (int i = 0; i < 1000; i++) {
        //            queue.offer(i + "");
        //        }
        //
        //        int size = queue.size();
        //        for (int i = 0; i < size; i++) {
        //            String poll = queue.poll();
        //            //            try {
        //            //                Thread.sleep(10);
        //            //            } catch (InterruptedException e) {
        //            //                throw new RuntimeException(e);
        //            //            }
        //            System.out.println("poll: " + poll);
        //        }

        Queue<Integer> queue = new LinkedList<>();

        // 向队列中添加元素
        queue.offer(1);
        queue.offer(2);
        queue.offer(3);

        // 查看队列头部的元素
        System.out.println("头部元素是：" + queue.peek());

        // 处理队列头部的元素
        int nextElement = queue.peek();
        System.out.println("处理头部元素：" + nextElement);

        // 再次查看头部元素
        System.out.println("处理后，头部元素仍然是：" + queue.peek());

    }

}
